package com.imax.center.service;

import java.util.Map;
import java.util.concurrent.CompletableFuture;

/**
 * 设备产生的数据服务接口
 */
public interface DeviceDataService {
    /**
     * 异步分析处理数据、入库到氚云
     */
    CompletableFuture<Boolean> asyncHandlerEvent(String message, Map<String, Object> data);

    /**
     * 同步分析处理数据、入库到氚云
     */
    void syncHandlerEvent(String message, Map<String, Object> data) throws InterruptedException;

}